package util.tool;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
/**
 * sql数据库简单封装
 * @author kong
 *
 */
public class Sqlite3 {
	private Connection c = null;
	private Statement stmt = null;
	ResultSet rs = null;
	/**
	 * 初始化数据库
	 * @return true 初始化成功
	 */
	public boolean openDb() {
		try {
			Class.forName("org.sqlite.JDBC");
			c = DriverManager.getConnection("jdbc:sqlite:data.db");
			stmt = c.createStatement();
		} catch (Exception e) {
			return false;
		}
		try {
			update("create table data(url text primary key,platform integer,publisher text,summitTime text,content text,title text,tags text, id text,imgUrl text);");
		} catch (Exception e) {
			
		}
		return true;
	}
	/**
	 * 执行更新
	 * @param sql 执行更新所需的sql语句
	 * @return 执行是否成功
	 */
	public boolean update(String sql) {
		try {
			stmt.executeUpdate(sql);			
		} catch (Exception e) {
			return false;
		}
		return true;
	}
	/**
	 * 执行查询，
	 * @param sql 执行查询所需的语句
	 * @return ResultSet,取下一个：rs.next(), getType(),注意，返回值如果是null，那就是执行失败了
	 */
	public ResultSet fetch(String sql) {
		try {
			return (rs = stmt.executeQuery(sql));
		} catch (Exception e) {
			return null;
		}
	}

}
